package com.jala.user.mq;

import com.jala.user.model.User;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.amqp.core.Message;
import org.springframework.stereotype.Component;


@Component
public class MessageListener {

    private final Logger logger= LoggerFactory.getLogger(MessageListener.class);



    public void onMkActivityShopLogMessage(User user){
        try {
            System.out.println("=============监听【QueueListenter】消息"+user);
            System.out.print("=====获取消息"+user);
		} catch (Exception e) {
			logger.error("error:"+e.getStackTrace());
		}
    }



}
